import pandas as pd
# 读取各个表格
kind_df = pd.read_csv('ERP_KHXD.csv')
fhjl_df = pd.read_csv('ERP_FHJL.csv')
user_df = pd.read_csv('sys_user.csv')
khxx_df = pd.read_csv('ERP_KHXX.csv')
dict_data_df = pd.read_csv('sys_dict_data.csv')
clxx_df = pd.read_csv('ERP_CLXX.csv')
khxd_df = pd.read_csv('ERP_KHXD.csv')
# 合并数据表
# 将发货记录表与客户下单表关联
merged_df = fhjl_df.merge(khxd_df, left_on='khxd_id', right_on='id', suffixes=('_fhjl', '_khxd'))

# 将合并后的表与用户信息表关联，以获取销售员名称
merged_df = merged_df.merge(user_df, left_on='create_by', right_on='user_name', suffixes=('', '_user'))

# 将合并后的表与客户信息表关联，以获取客户名称
merged_df = merged_df.merge(khxx_df, left_on='khxx_id_fhjl', right_on='id', suffixes=('', '_khxx'))

# 将合并后的表与车辆信息表关联，以获取车辆信息
merged_df = merged_df.merge(clxx_df, left_on='clxx_id', right_on='id', suffixes=('', '_clxx'))

# 打印合并后的数据框架的列名
print(merged_df.columns)
final_df = merged_df[['id_fhjl', 'create_time', 'nick_name', 'ywlx_code', 'khmc', 'fhd_id', 'zd_id', 'hplx_khxd', 'cpgg_khxd', 'cppp_khxd', 'fhdw', 'dzdw', 'dj', 'hk', 'cph']]
# 重命名字段
final_df.columns = [
    '发货记录ID', '发货记录完成时间', '销售员名称', '业务类型', '客户名称',
    '发货地名称', '站点名称', '货品类型', '产品规格', '产品品牌',
    '发货吨位', '到站吨位', '单价', '货款', '送货车辆车牌'
]
# 保存为新的CSV文件
final_df.to_csv('merge_data1.csv', index=False)
print(final_df.columns)
print("关联操作完成，结果已保存到merged_data1.csv文件中。")